package com.pengpeng.rabbitmq.producer.send;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.ReturnedMessage;
import org.springframework.stereotype.Service;

/**
 * @author 彭鹏
 * @date 2021/10/19.
 */
@Service
public class SendService extends AbstractSendService {
    @Override
    public void handleConfirmCallback(String messageId, boolean ack, String cause) {
        this.logger.info("handleConfirmCallback 默认实现发送确认的处理方法！！！");
    }

    @Override
    public void handleReturnCallback(Message message, int replyCode, String replyText, String routingKey) {
        this.logger.info("handleReturnCallback 默认实现发送匹配不上队列时 回调函数的处理！！！");
    }

    @Override
    public void returnedMessage(ReturnedMessage returnedMessage) {
        this.logger.info("returnedMessage 默认实现发送匹配不上队列时 回调函数的处理！！！");
    }
}

